package com.hzy.kafka.entity;

import com.alibaba.fastjson.annotation.JSONField;
import com.fasterxml.uuid.Generators;
import com.fasterxml.uuid.UUIDGenerator;
import com.hzy.kafka.enums.KafkaConstants;
import lombok.Data;

import java.util.Date;
import java.util.concurrent.TimeUnit;

@Data
public class DelayMessage {
    /**
     * 事件唯一ID,用于去重检查
     */
    private String eventId = Generators.randomBasedGenerator().generate().toString();

    /**
     * 有效期
     */
    private Long time;

    /**
     * 单位
     */
    private TimeUnit unit;

    /**
     * 内容
     */
    private String context;

    /**
     * 真实Topic
     */
    private String actualTopic;
}
